package com.gzx.plugin.tjzy.modular.sse.service;

import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 * @author zjt
 * @description
 * @since 2025/4/29 17:40
 */
public interface GzxSseService {

    /**
     * 初始化SSE连接
     *
     * @param clientId
     */
    SseEmitter initSse(String clientId);

    /**
     * 发送消息
     */
    void sendMessage();

    /**
     * 给所有人发通知
     *
     * @param type
     * @param msg
     */
    void sendAll(String type, String msg);
}
